package com.syf.config.rocket;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * 发送消息到MQ：
 *      Source.@Output("order_out") -> yml: 指定队列名称order_in   order_out: {destination: order_in
 *      ->  match模块中监听队列Sink.@Input("order_in")  -> yml中 order_in: {destination: order_in
 */
public interface Source {

    /**
     * 1.发送委托单到撮合系统里面
     * 2.撤销委托单 -》 将该委托单从撮合引擎里面的委托单账本里面移除
     *
     */
    @Output("order_out")
    MessageChannel outputMessage() ;
}
